package org.future.task.core.task;

import org.future.task.core.handler.Connection;
import org.future.task.core.handler.TransForm;

import java.util.Map;

public class Task<Flow> {

    private String queueName;

    private int nativeQueueSize;

    private int readBatch;

    private int threadSize;

    private String runnableClass;

    private boolean useCache;

    private Connection connection;

    private Map<String, Object> properties;

    private Map<String, Object> singleBeans;

    private TransForm<Flow> transForm;

    private int commitThreadSize;

    public String getQueueName() {
        return queueName;
    }

    public void setQueueName(String queueName) {
        this.queueName = queueName;
    }

    public int getNativeQueueSize() {
        return nativeQueueSize;
    }

    public void setNativeQueueSize(int nativeQueueSize) {
        this.nativeQueueSize = nativeQueueSize;
    }

    public int getThreadSize() {
        return threadSize;
    }

    public void setThreadSize(int threadSize) {
        this.threadSize = threadSize;
    }

    public String getRunnableClass() {
        return runnableClass;
    }

    public void setRunnableClass(String runnableClass) {
        this.runnableClass = runnableClass;
    }

    public boolean isUseCache() {
        return useCache;
    }

    public void setUseCache(boolean useCache) {
        this.useCache = useCache;
    }

    public Connection getConnection() {
        return connection;
    }

    public void setConnection(Connection connection) {
        this.connection = connection;
    }

    public Map<String, Object> getProperties() {
        return properties;
    }

    public void setProperties(Map<String, Object> properties) {
        this.properties = properties;
    }

    public Map<String, Object> getSingleBeans() {
        return singleBeans;
    }

    public void setSingleBeans(Map<String, Object> singleBeans) {
        this.singleBeans = singleBeans;
    }

    public TransForm<Flow> getTransForm() {
        return transForm;
    }

    public void setTransForm(TransForm<Flow> transForm) {
        this.transForm = transForm;
    }

    public int getCommitThreadSize() {
        return commitThreadSize;
    }

    public void setCommitThreadSize(int commitThreadSize) {
        this.commitThreadSize = commitThreadSize;
    }

    public int getReadBatch() {
        return readBatch;
    }

    public void setReadBatch(int readBatch) {
        this.readBatch = readBatch;
    }
}
